78a85047c71d53ad9ad74e5eed5b9ccf1d9cce36,samza-core/src/test/java/org/apache/samza/container/grouper/task/TestTaskAssignmentManager.java,TestTaskAssignmentManager,testTaskAssignmentManagerEmptyCoordinatorStream,#,139

Before Change


    taskAssignmentManager.register(new TaskName("ignoredTaskName"));
    assertTrue(producer.isRegistered());
    assertEquals(producer.getRegisteredSource(), "SamzaTaskAssignmentManager");
    assertTrue(consumer.isRegistered());

    taskAssignmentManager.start();
    assertTrue(producer.isStarted());

After Change


        mockCoordinatorStreamSystemFactory.getCoordinatorStreamSystemProducer(config, null);
    MockCoordinatorStreamSystemConsumer consumer =
        mockCoordinatorStreamSystemFactory.getCoordinatorStreamSystemConsumer(config, null);
    consumer.register();
    TaskAssignmentManager taskAssignmentManager = new TaskAssignmentManager(producer, consumer);

    assertTrue(producer.isRegistered());